package com.longe.channel;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

/**
 * 自定义的消息通道
 */
public interface MyProcessor {

	//消息生产者的配置
	String MY_OUTPUT = "my_output";
	//消息消费者的配置
	String MY_INPUT = "my_input";

	@Output("my_output")
	MessageChannel my_output();

	@Input("my_input")
	SubscribableChannel my_input();
}